package com.muchfish.reactor.api;

import reactor.core.publisher.Flux;
import java.util.stream.Stream;

public class ReactorJavaStreamIntegrationExample {
    public static void main(String[] args) {
        Flux<Integer> flux = Flux.fromStream(Stream.of(1, 2, 3, 4, 5));

        flux.subscribe(System.out::println); // 输出: 1, 2, 3, 4, 5
    }
}
